package com.yl.flink.processor;

import lombok.extern.slf4j.Slf4j;
import org.apache.flink.api.common.functions.MapFunction;

/**
 * @author wlf
 * @since 2022/8/17
 */
@Slf4j
public class PrintPayloadFunc implements MapFunction<String, String> {

    /**
     * @param element 流元素
     */
    @Override
    public String map(String element) throws Exception {
        log.info("payload: {}", element);
        return element;
    }
}
